backup.ts ➔ backup - Code Metrics - Inspection of "fix travis #2" - dimaslanjaka/universal-framework - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( cdadad...8d09a6 )

by Dimas

created 2020-07-04 13:01 UTC

backup.ts ➔ backup B

↳ Parent: libs/src/archiver/backup.ts

Complexity

Conditions

Size

Total Lines	75
Code Lines	47

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	7
eloc	47
dl	0
loc	75
rs	7.3345
c	0
b	0
f	0

How to fix Long Method

import archiver from "archiver";
import fs from "fs";
import process from "process";
import path from "path";
import core from "./../compiler/core";
const log = core.log;
const root = process.cwd();

/**
 * Get function name
 */
export function getFuncName() {
  return getFuncName.caller.name;
}

/**
 * Read directory with deep options
 * @param directory directory scan target
 * @param deep true for recursive scan, false only scan the folder not subfolder
 * @param fileslist files to concat
 * @example ['node_modules', /\/node_modules\//]
 * @param filter
 * @example files only { folders true, files false }
 * @example folder only { files true, folder false }
 */
export function readdir(
  directory: string,
  deep: boolean,
  fileslist: null | string[] = [],
  exclude: Array<string | RegExp> = [],
  filter: null | {
    /**
     * Filter files from results (remove)
     */
    files: boolean;
    /**
     * Filter directory from results (remove)
     */
    folders: boolean;
  } = null
) {
  if (!directory) {
    log.log("directory(" + log.type(typeof directory) + ") not valid");
    return;
  }
  if (!fileslist) {
    fileslist = [];
  } else if (!fileslist.length) {
    fileslist = [];
  } else if (fileslist.length) {
    fileslist = fileslist;
  }
  const doRead = function (directory: string) {
    var files = fs.readdirSync(directory, { encoding: "utf-8" });
    files.forEach(function (file) {
      file = path.resolve(file);
      if (Array.isArray(fileslist)) {
        fileslist.push(file);
        var isDir = fs.lstatSync(file).isDirectory();
        if (deep) {
          if (isDir) {
            fileslist = readdir(file, deep, fileslist);
          }
        }
      }
    });
    if (exclude && exclude.length) {
      exclude.forEach(function (ex) {
        fileslist = fileslist.filter(function (item) {
          var allow = null;
          item = core.normalize(item);
          if (ex instanceof RegExp) {
            allow = !ex.test(item);
          } else {
            var matches = item.indexOf(ex) !== -1;
            allow = !matches;
          }
          return allow;
        });
      });
    }
    //log.log(typeof filter == "object");
    if (filter) {
      fileslist = fileslist.filter(function (item) {
        var type = fs.statSync(item);
        if (filter.hasOwnProperty("files") && filter.files) {
          return !type.isFile();
        } else if (filter.hasOwnProperty("folders") && filter.folders) {
          return !type.isDirectory();
        }
        return null;
      });
    }
    //log.log(filter);

    return fileslist;
  };

  return doRead(directory);
}

export function backup() {
  const fn = getFuncName();

  // create a file to stream archive data to.
  var output = fs.createWriteStream(root + "/tmp/backup.zip");
  var archive = archiver("zip", {
    zlib: { level: 9 }, // Sets the compression level.
  });

  // listen for all archive data to be written
  // 'close' event is fired only when a file descriptor is involved
  output.on("close", function () {
    console.log(archive.pointer() + " total bytes");
    console.log(
      "archiver has been finalized and the output file descriptor has closed."
    );
  });

  // This event is fired when the data source is drained no matter what was the data source.
  // It is not part of this library but rather from the NodeJS Stream API.
  // @see: https://nodejs.org/api/stream.html#stream_event_end
  output.on("end", function () {
    console.log("Data has been drained");
  });

  // good practice to catch warnings (ie stat failures and other non-blocking errors)
  archive.on("warning", function (err) {
    if (err.code === "ENOENT") {
      // log warning
    } else {
      // throw error
      throw err;
    }
  });

  // good practice to catch this error explicitly
  archive.on("error", function (err) {
    throw err;
  });

  // pipe archive data to the file
  archive.pipe(output);
  /**
   * Process archive
   * @param files
   */
  const archive_now = function (files: string[]) {
    if (files.length) {
      if (!fs.existsSync(files[0])) {
        if (!fs.existsSync(fromRoot(files[0]))) {
          log.log(log.error(`${fn}(${files[0]}) not found`));
          return;
        }
        files[0] = fromRoot(files[0]);
      }
      var type = fs.lstatSync(files[0]);
      var filename = path.basename(files[0]);
      if (type.isFile()) {
        archive.append(fs.createReadStream(files[0]), {
          name: filename,
        });
      } else if (type.isDirectory()) {
        archive.directory(fromRoot(files[0]), filename);
      }
      files.shift();
      archive_now(files);
    }
  };

  archive_now(
    readdir(fromRoot("/"), false, null, null, { folders: true, files: false })
  );
  archive_now(["src", "assets", ".vscode", "views", "libs"]);

  // finalize the archive (ie we are done appending files but streams have to finish yet)
  // 'close', 'end' or 'finish' may be fired right after calling this method so register to them beforehand
  archive.finalize();
}

export function fromRoot(dest: string) {
  return path.join(root, dest);
}


1			import archiver from "archiver";
2			import fs from "fs";
3			import process from "process";
4			import path from "path";
5			import core from "./../compiler/core";
6			const log = core.log;
7			const root = process.cwd();
8
9			/**
10			* Get function name
11			*/
12			export function getFuncName() {
13			return getFuncName.caller.name;
14			}
15
16			/**
17			* Read directory with deep options
18			* @param directory directory scan target
19			* @param deep true for recursive scan, false only scan the folder not subfolder
20			* @param fileslist files to concat
21			* @example ['node_modules', /\/node_modules\//]
22			* @param filter
23			* @example files only { folders true, files false }
24			* @example folder only { files true, folder false }
25			*/
26			export function readdir(
27			directory: string,
28			deep: boolean,
29			fileslist: null \| string[] = [],
30			exclude: Array<string \| RegExp> = [],
31			filter: null \| {
32			/**
33			* Filter files from results (remove)
34			*/
35			files: boolean;
36			/**
37			* Filter directory from results (remove)
38			*/
39			folders: boolean;
40			} = null
41			) {
42			if (!directory) {
43			log.log("directory(" + log.type(typeof directory) + ") not valid");
44			return;
45			}
46			if (!fileslist) {
47			fileslist = [];
48			} else if (!fileslist.length) {
49			fileslist = [];
50			} else if (fileslist.length) {
51			fileslist = fileslist;
52			}
53			const doRead = function (directory: string) {
54			var files = fs.readdirSync(directory, { encoding: "utf-8" });
55			files.forEach(function (file) {
56			file = path.resolve(file);
57			if (Array.isArray(fileslist)) {
58			fileslist.push(file);
59			var isDir = fs.lstatSync(file).isDirectory();
60			if (deep) {
61			if (isDir) {
62			fileslist = readdir(file, deep, fileslist);
63			}
64			}
65			}
66			});
67			if (exclude && exclude.length) {
68			exclude.forEach(function (ex) {
69			fileslist = fileslist.filter(function (item) {
70			var allow = null;
71			item = core.normalize(item);
72			if (ex instanceof RegExp) {
73			allow = !ex.test(item);
74			} else {
75			var matches = item.indexOf(ex) !== -1;
76			allow = !matches;
77			}
78			return allow;
79			});
80			});
81			}
82			//log.log(typeof filter == "object");
83			if (filter) {
84			fileslist = fileslist.filter(function (item) {
85			var type = fs.statSync(item);
86			if (filter.hasOwnProperty("files") && filter.files) {
87			return !type.isFile();
88			} else if (filter.hasOwnProperty("folders") && filter.folders) {
89			return !type.isDirectory();
90			}
91			return null;
92			});
93			}
94			//log.log(filter);
95
96			return fileslist;
97			};
98
99			return doRead(directory);
100			}
101
102			export function backup() {
103			const fn = getFuncName();
104
105			// create a file to stream archive data to.
106			var output = fs.createWriteStream(root + "/tmp/backup.zip");
107			var archive = archiver("zip", {
108			zlib: { level: 9 }, // Sets the compression level.
109			});
110
111			// listen for all archive data to be written
112			// 'close' event is fired only when a file descriptor is involved
113			output.on("close", function () {
114			console.log(archive.pointer() + " total bytes");
115			console.log(
116			"archiver has been finalized and the output file descriptor has closed."
117			);
118			});
119
120			// This event is fired when the data source is drained no matter what was the data source.
121			// It is not part of this library but rather from the NodeJS Stream API.
122			// @see: https://nodejs.org/api/stream.html#stream_event_end
123			output.on("end", function () {
124			console.log("Data has been drained");
125			});
126
127			// good practice to catch warnings (ie stat failures and other non-blocking errors)
128			archive.on("warning", function (err) {
129			if (err.code === "ENOENT") {
130			// log warning
131			} else {
132			// throw error
133			throw err;
134			}
135			});
136
137			// good practice to catch this error explicitly
138			archive.on("error", function (err) {
139			throw err;
140			});
141
142			// pipe archive data to the file
143			archive.pipe(output);
144			/**
145			* Process archive
146			* @param files
147			*/
148			const archive_now = function (files: string[]) {
149			if (files.length) {
150			if (!fs.existsSync(files[0])) {
151			if (!fs.existsSync(fromRoot(files[0]))) {
152			log.log(log.error(`${fn}(${files[0]}) not found`));
153			return;
154			}
155			files[0] = fromRoot(files[0]);
156			}
157			var type = fs.lstatSync(files[0]);
158			var filename = path.basename(files[0]);
159			if (type.isFile()) {
160			archive.append(fs.createReadStream(files[0]), {
161			name: filename,
162			});
163			} else if (type.isDirectory()) {
164			archive.directory(fromRoot(files[0]), filename);
165			}
166			files.shift();
167			archive_now(files);
168			}
169			};
170
171			archive_now(
172			readdir(fromRoot("/"), false, null, null, { folders: true, files: false })
173			);
174			archive_now(["src", "assets", ".vscode", "views", "libs"]);
175
176			// finalize the archive (ie we are done appending files but streams have to finish yet)
177			// 'close', 'end' or 'finish' may be fired right after calling this method so register to them beforehand
178			archive.finalize();
179			}
180
181			export function fromRoot(dest: string) {
182			return path.join(root, dest);
183			}
184

dimaslanjaka / universal-framework

Push — master ( cdadad...8d09a6 )

backup.ts ➔ backup B

Complexity

Size

Duplication

Importance

How to fix Long Method

Long Method

Duplication Side-by-Side

Filter issues like